// package: rewords-server-2024
// filename: cmd
// author: diogoxiang@gmail.com
// time: 2024/7/12 上午10:58

package cmd

import (
	"context"
	"github.com/gogf/gf/v2/frame/g"
	"github.com/gogf/gf/v2/net/ghttp"
	"github.com/gogf/gf/v2/os/gcmd"
	"github.com/gogf/gf/v2/util/gconv"
	"rewords-server-2024/internal/router"
	"rewords-server-2024/internal/service"
)

// 启动参数
type startInfo struct {
	Port int `json:"port"`
}

var (
	Http = &gcmd.Command{
		Name:  "http",
		Usage: "http",
		Brief: "HTTP服务，也可以称为主服务，包含http、websocket、tcpserver多个可对外服务",
		Func: func(ctx context.Context, parser *gcmd.Parser) (err error) {
			// 初始化http服务
			s := g.Server()

			// 初始化请求前回调
			s.BindHookHandler("/*any", ghttp.HookBeforeServe, service.Hook().BeforeServe)

			// 请求响应结束后回调
			s.BindHookHandler("/*any", ghttp.HookAfterOutput, service.Hook().AfterOutput)

			// 注册全局中间件
			s.BindMiddleware("/*any", []ghttp.HandlerFunc{
				service.Middleware().Ctx,  // 初始化请求上下文，一般需要第一个进行加载，后续中间件存在依赖关系
				service.Middleware().CORS, // 跨域中间件，自动处理跨域问题
				//service.Middleware().Blacklist,       // IP黑名单中间件，如果请求IP被后台拉黑，所有请求将被拒绝
				service.Middleware().DemoLimit,       // 演示系統操作限制，当开启演示模式时，所有POST请求将被拒绝
				service.Middleware().PreFilter,       // 请求输入预处理，api使用gf规范路由并且XxxReq结构体实现了validate.Filter接口即可隐式预处理
				service.Middleware().ResponseHandler, // HTTP响应预处理，在业务处理完成后，对响应结果进行格式化和错误过滤，将处理后的数据发送给请求方
			}...)

			// 全局路由前缀
			globalPrefix, _ := g.Cfg().Get(ctx, "server.backGlobal", "/")
			//初始路由
			s.Group(gconv.String(globalPrefix), func(group *ghttp.RouterGroup) {
				// 初始化api路由
				router.Api(ctx, group)

				// 初始化admin路由
				router.Admin(ctx, group)

				// amis 静态json
				router.Static(ctx, group)

				// 初始化 wechat 路由
				router.WxApp(ctx, group)

			})

			// 添加一个协程，用于监听服务关闭信号，当收到服务关闭信号时，关闭http服务
			serverWg.Add(1)

			// 信号监听
			signalListen(ctx, signalHandlerForOverall)

			go func() {
				<-serverCloseSignal
				//websocket.Stop()              // 关闭websocket
				//service.TCPServer().Stop(ctx) // 关闭tcp服务器
				//addons.StopModules(ctx)       // 停止插件
				_ = s.Shutdown() // 关闭http服务，主服务建议放在最后一个关闭
				g.Log().Debug(ctx, "http successfully closed ..")
				serverWg.Done()
			}()

			s.SetServerAgent("DioServer")
			// 绑定端口
			s.SetPort(gconv.Int(g.Cfg().MustGet(ctx, "server.apiport")))
			// Just run the server.
			s.Run()
			return
		},
	}
)
